// Copyright (C) 2023 即时通讯网(52im.net) & Jack Jiang.
// The RainbowChat Project. All rights reserved.
// 
// 【本产品为著作权产品，合法授权后请放心使用，禁止外传！】
// 【本次授权给：<北京小羊驼科技有限公司>，授权编号：<NT231212144350>，代码指纹：<A.702363430.550>，技术对接人微信：<ID: wxid_wbyootvkdcgj22>】
// 【授权寄送：<收件：苏先生、地址：北京市大兴区北京密码西区6号楼1单元301、电话：18613885610、邮箱：bd@huiyuanxiang-inc.com>】
// 
// 【本系列产品在国家版权局的著作权登记信息如下】：
// 1）国家版权局登记名(简称)和权证号：RainbowChat    （证书号：软著登字第1220494号、登记号：2016SR041877）
// 2）国家版权局登记名(简称)和权证号：RainbowChat-Web（证书号：软著登字第3743440号、登记号：2019SR0322683）
// 3）国家版权局登记名(简称)和权证号：RainbowAV      （证书号：软著登字第2262004号、登记号：2017SR676720）
// 4）国家版权局登记名(简称)和权证号：MobileIMSDK-Web（证书号：软著登字第2262073号、登记号：2017SR676789）
// 5）国家版权局登记名(简称)和权证号：MobileIMSDK    （证书号：软著登字第1220581号、登记号：2016SR041964）
// * 著作权所有人：江顺/苏州网际时代信息科技有限公司
// 
// 【违法或违规使用投诉和举报方式】：
// 联系邮件：jack.jiang@52im.net
// 联系微信：hellojackjiang
// 联系QQ号：413980957
// 授权说明：http://www.52im.net/thread-1115-1-1.html
// 官方社区：http://www.52im.net
package com.x52im.mall;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import com.eva.framework.HttpController;
import com.eva.framework.Processor;
import com.eva.framework.Processor.User;
import com.eva.framework.dto.DataFromClient;
import com.eva.framework.dto.SysProcessorConst;
import com.eva.framework.utils.EndsExceptionFactory;
import com.eva.framework.utils.LoggerFactory;
import com.x52im.mall.dto.CommonProcessorConst;
import com.x52im.mall.score.ScoreProcessor;
import com.x52im.mall.shop.ShopProcessor;
import com.x52im.rainbowchat.common.dto.cnst.MyProcessorConst;

/**
 * MVC之核心控制器实现类.<br>
 * 本子类只需实现用户级的业务逻辑.<br>
 * 
 * @author Jack Jiang(http://www.52im.net/space-uid-1.html)
 * @version 1.0
 */
public class MyController extends HttpController//HttpController
{
	private FWBaseProcessor fwBaseProcessor = new FWBaseProcessor();
	
	// ******************************************************************* For Robotime Mall START
	/** 积分管理功能集业务处理器 */
	private ScoreProcessor scoreProcessor = new ScoreProcessor();
	/** 购物管理功能集业务处理器(需要用户登陆后才能做的操作) */
	private ShopProcessor shopProcessor = new ShopProcessor();
	/** 购物管理功能集业务处理器(不需要用户登陆就能做的操作) */
	private com.x52im.mall.shop.ShopProcessor$NoNeedAuthed shopProcessorNoNeedAuthed
			= new com.x52im.mall.shop.ShopProcessor$NoNeedAuthed();
	// ******************************************************************* For Robotime Mall END
	
	/**
	 * <p>
	 * 核心调度处理方法.<br>
	 * <br>
	 * 本方法默认会进行用户登陆认证处理:<br>
	 * <ul>
	 * <li>当参数{@code fc}中的DataFromClient.getProcessorId()== {@link SysProcessorConst#PROCESSSOR_LOGIN}
	 * 时，进行用户登陆认证处理——首先进行版本检查 {@link #checkClientVersion(DataFromClient, HttpServletRequest, HttpServletResponse)}
	 * ，接着再调用方法 {@link #login(DataFromClient, HttpServletRequest, HttpServletResponse)}验证登陆信息.</li>
	 * <li>当参数{@code fc}中的 DataFromClient.getProcessorId()== {@link SysProcessorConst#PROCESSSOR_LOGOUT}
	 * 时，进行用户登陆(会话)注销处理( {@link HttpSession#invalidate()} ).</li>
	 * <li>否则如果用户已经是经过登陆认证的合法用户则直接进入方法 {@link #switchUserProcessor(DataFromClient, HttpServletRequest, HttpServletResponse, User)}
	 * 进行其它业务请求调度处理，如果用户不是合法用户则直接拒绝处理请求并抛出异常. </li>
	 * </ul>
	 * 
	 * <b>额外说明：</b>本方法在登陆验证时会首先完成客户端版本检查(具体怎么检查取决你的{@link #checkClientVersion(DataFromClient
	 * , HttpServletRequest, HttpServletResponse)}方法的实现，在检查通过的情况下才会进行用户登陆验证哦
	 * （比如在大名移动通的实现逻辑里需要更新时首先返回更新信息给客户端完成更新后再登陆才行，否则无条件中断用户登陆验证）.
	 * </p>
	 * 
	 * @param fc 封装了客户端发过来的相关数据（本方法中是必须的参数）
	 * @param req 客户端请求实例引用（把它传过来完全是未了考虑以后可能有其它作用，本方法中它不是必须的）
	 * @param res 客户端响应实例引用（把它传过来完全是未了考虑以后可能有其它作用，本方法中它不是必须的）
	 * @return 处理完返回的对象（要给客户端的）
	 * @throws Exception 本方法调用中出现任何异常时都会抛出，方法将中断执行
	 * @see #switchUserProcessor(DataFromClient, HttpServletRequest, HttpServletResponse, User)
	 */
	@Override protected Object dispatch(DataFromClient fc, HttpServletRequest req,
			HttpServletResponse res) throws Exception
	{
//		// TODO rainbowchat自2014-04-22日晚9点10分左右关闭，日后再开放：目前远程代码都是2.5.1最新，但google play上应被禁用暂时不能更新！！
//		EException ee = new EException("Service not avaliable!!");
//		ee.setShortMessage("I'm sorry! KChat service suspended, and will be open later, please pay attention!");
//		throw ee;
		
		Object retObj = null;
		int processor_id = fc.getProcessorId();
		String hello_word = req.getHeader("hello_word");//目前本字段尚未有具体用途，留待以后扩展用
		//这样的解编码可解决头信息中的乱码
//		String user = new String(req.getHeader("user").getBytes("iso-8859-1"),"GB2312");
		LoggerFactory.getLog().debug("[HTTP]hello_word="+hello_word+" processor_id="+processor_id);
//		HttpSession hs = null;
		
		Processor processor = null;
		switch(processor_id)
		{
			case MyProcessorConst.PROCESSSOR_FW_BASE:
				processor = fwBaseProcessor;
				break;

			// ************************************************ For Mall START
			//
			case CommonProcessorConst.PROCESSOR_SCORE:
				processor = scoreProcessor;
				break;
			//
			case CommonProcessorConst.PROCESSOR_SHOP_NEED$AUTHED:
				processor = shopProcessor;
				break;
			//
			case CommonProcessorConst.PROCESSOR_SHOP_NO$NEED$AUTHED:
				processor = shopProcessorNoNeedAuthed;
				break;
			// ************************************************ For Mall END
			
			default://找不到处理器
				throw EndsExceptionFactory.INVALID_PROCESSOR_ID(processor_id);
		}
		
		String basePath = req.getScheme()+"://"+req.getServerName()+":"+req.getServerPort()+req.getContextPath() + "/";
		System.out.println("[HTTP]basePath = " +  basePath);
		// 借用一个User对象，仅仅是用来存放Ip地址而已
		User u = new User();
		u.setIp(req.getRemoteHost());
		if (processor != null)
		{
			retObj = processor.process(fc.getJobDispatchId()
						,fc.getActionId(),fc.getNewData()
						,fc.getOldData(), u);
		}
		return retObj;
	}
}
